package cn.oldsix.spark.streaming.spark

import cn.oldsix.spark.streaming.vo.{UserBehaviour, UserBehaviourDetail}
import com.esotericsoftware.kryo.Kryo
import org.apache.spark.serializer.KryoRegistrator

/*
* @Author : Wu.D.J
* @Create : 2018.09.15
**/
class MyKryoRegistrator extends KryoRegistrator{

    override def registerClasses(kryo: Kryo): Unit = {
        kryo.register(classOf[UserBehaviour])
        kryo.register(classOf[UserBehaviourDetail])
    }
}
